from celery import Celery

# 1.实例化Celery应用，命名为'one'，并配置RabbitMQ作为消息代理
# 这里使用了RabbitMQ的默认凭据和端口
app = Celery('one', broker='redis://127.0.0.1:6379/3',backend='redis://localhost:6379/3')
# 2.定义一个异步任务
@app.task
def add(x, y):
    """
    加法任务

    该任务函数接收两个参数，并返回它们的和。这是为了演示如何在Celery中定义一个简单的任务。

    参数:
    x (int): 第一个加数
    y (int): 第二个加数

    返回:
    int: 两个参数的和
    """
    # 开始执行加法任务时的打印信息，包含输入参数
    print(f"开始执行加法任务：{x} + {y}")

    # 执行加法运算
    result = x + y

    # 加法任务完成时的打印信息，包含计算结果
    print(f"加法任务完成，结果：{result}")

    # 返回计算结果
    return result
